package com.ilxqx.framework.amqp.service;

import com.ilxqx.framework.amqp.po.SysRabbitMessage;
import com.rabbitmq.client.Channel;

import java.util.Map;

/**
 * 消息接受服务类
 * @author venus
 */
public interface MessageReceiverService {

    /**
     * 消息处理
     * @param message 消息
     * @param channel 消息通道
     * @param headers 头部信息
     */
    void onMessage(SysRabbitMessage message, Channel channel, Map<String, Object> headers);

}
